package edu.ncsu.csc.streamingmr;
import java.io.IOException;

import org.apache.hadoop.mapred.RecordReader;

public interface InputStreamFormat<K, V> {
	/**
	 * feed in an bytebuffer. returns several StreamBatches for dispatching to different task.
	 */
	public StreamBatch[] getStreamBatch(byte[] inputstream) throws IOException;
	
	public RecordReader<K, V> getRecordReader(StreamBatch batch);
	
	public int getRecordSize();
}
